package demo.consumer.listener;

import demo.consumer.bindler.EchoBinding;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

import java.io.IOException;

@EnableBinding(EchoBinding.class)
public class HelloListener {

    @StreamListener(target = EchoBinding.GREETING)
    public void processChannelGreeting(String msg) throws IOException {
        System.out.println("RECV:" + msg);
    }

}
